Micron Document
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| SparkN0de-git | SparkN0de |
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Node / ReticulumProjects / MeshChatX.git / commits / 398500c


Commit 398500c25511ae353e486cb257aa1d1aa8c1b0e2

󰉖 Browse tree at this commit

Parents : c7abf36
Author : Ivan <ivan@quad4.io>
Signature : Signature validation error
Date : 2026-04-14T21:12:06-05:00

fix(tests): update anomaly flooding test to ensure consistent behavior by resetting state and increasing warning count

Changes

1 files changed, 11 insertions(+), 4 deletions(-)

M tests/backend/test_debug_logs.py +11 -4

Diff

diff --git a/tests/backend/test_debug_logs.py b/tests/backend/test_debug_logs.py
index ef7a260a..9a25e408 100644
--- a/tests/backend/test_debug_logs.py
+++ b/tests/backend/test_debug_logs.py
@@ -62,14 +62,21 @@ def test_search_and_filter(handler, db):
def test_anomaly_flooding(handler, db):
persistent_handler, logger = handler
persistent_handler.flooding_threshold = 5
-
- for i in range(10):
+ # Flooding uses a 1s window from last_reset_time. The handler may be created
+ # well before this loop on slow CI; if the 6th warning falls after that second,
+ # the counter resets and totals never exceed the threshold. Reset state here and
+ # emit enough warnings to survive one mid-burst reset.
+ with persistent_handler.lock:
+ persistent_handler.message_counts.clear()
+ persistent_handler.last_reset_time = time.time()
+
+ for i in range(15):
logger.warning(f"Message {i}")
- # Wait for flush
+ time.sleep(0.2)
logger.debug("Force flush")
- logs = persistent_handler.get_logs(limit=20)
+ logs = persistent_handler.get_logs(limit=30)
anomalies = [log for log in logs if log["is_anomaly"]]
assert len(anomalies) > 0
assert any(log["anomaly_type"] == "flooding" for log in anomalies)


──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────